package com.xiaohu.implclass;

import com.xiaohu.bean.WaterSensor;
import org.apache.flink.api.common.functions.MapFunction;

public class MyMapFunction1 implements MapFunction<WaterSensor,String> {

    @Override
    public String map(WaterSensor value) throws Exception {
        return value.getId();
    }
}
